Node / ReticulumProjects / MeshChatX.git / files / meshchatx / src / frontend / js / WebSocketConnection.js

Displaying Raw • Download

Tff7b72import Te6edf3mitt Tff7b72from Ta5d6ff"mitt"Tb4b4b4;

Tff7b72class Te6edf3WebSocketConnection Tb4b4b4{

Tff7b72constructorTb4b4b4(Tb4b4b4) Tb4b4b4{

Tff7b72thisTb4b4b4.Te6edf3emitter Tff7b72= Te6edf3mittTb4b4b4(Tb4b4b4)Tb4b4b4;

Tff7b72thisTb4b4b4.Te6edf3isDemoMode Tff7b72= Tff7b72falseTb4b4b4;

Tff7b72thisTb4b4b4.Te6edf3ws Tff7b72= Tff7b72nullTb4b4b4;

Tff7b72thisTb4b4b4.Te6edf3pingInterval Tff7b72= Tff7b72nullTb4b4b4;

Tff7b72thisTb4b4b4.Te6edf3initialized Tff7b72= Tff7b72falseTb4b4b4;

Tff7b72thisTb4b4b4.Te6edf3checkDemoModeAndConnectTb4b4b4(Tb4b4b4)Tb4b4b4;

Tb4b4b4}

Tff7b72async Te6edf3checkDemoModeAndConnectTb4b4b4(Tb4b4b4) Tb4b4b4{

Tff7b72if Tb4b4b4(Tff7b72typeof Tffa657window Tff7b72=== Ta5d6ff"undefined" Tff7b72|| Tff7b72!Tffa657windowTb4b4b4.Te6edf3axiosTb4b4b4) Tb4b4b4{

Te6edf3setTimeoutTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Tff7b72thisTb4b4b4.Te6edf3checkDemoModeAndConnectTb4b4b4(Tb4b4b4)Tb4b4b4, T79c0ff100Tb4b4b4)Tb4b4b4;

Tff7b72returnTb4b4b4;

Tb4b4b4}

Tff7b72try Tb4b4b4{

Tff7b72const Te6edf3response Tff7b72= Tff7b72await Tffa657windowTb4b4b4.Te6edf3axiosTb4b4b4.Te6edf3getTb4b4b4(Ta5d6ff"/api/v1/app/info"Tb4b4b4)Tb4b4b4;

Tff7b72thisTb4b4b4.Te6edf3isDemoMode Tff7b72= Te6edf3responseTb4b4b4.Te6edf3dataTb4b4b4.Te6edf3app_infoTff7b72?Tb4b4b4.Te6edf3is_demo Tff7b72=== Tff7b72trueTb4b4b4;

Tb4b4b4} Tff7b72catch Tb4b4b4(Te6edf3eTb4b4b4) Tb4b4b4{

T8b949e// If we can't check, assume not demo mode and try to connect

Tb4b4b4}

Tff7b72thisTb4b4b4.Te6edf3initialized Tff7b72= Tff7b72trueTb4b4b4;

Tff7b72if Tb4b4b4(Tff7b72!Tff7b72thisTb4b4b4.Te6edf3isDemoModeTb4b4b4) Tb4b4b4{

Tff7b72thisTb4b4b4.Te6edf3reconnectTb4b4b4(Tb4b4b4)Tb4b4b4;

Tff7b72thisTb4b4b4.Te6edf3pingInterval Tff7b72= Te6edf3setIntervalTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Tb4b4b4{

Tff7b72thisTb4b4b4.Te6edf3pingTb4b4b4(Tb4b4b4)Tb4b4b4;

Tb4b4b4}Tb4b4b4, T79c0ff30000Tb4b4b4)Tb4b4b4;

Tb4b4b4}

Tb4b4b4}

T8b949e// add event listener

Te6edf3onTb4b4b4(Te6edf3eventTb4b4b4, Te6edf3handlerTb4b4b4) Tb4b4b4{

Tff7b72thisTb4b4b4.Te6edf3emitterTb4b4b4.Te6edf3onTb4b4b4(Te6edf3eventTb4b4b4, Te6edf3handlerTb4b4b4)Tb4b4b4;

Tb4b4b4}

T8b949e// remove event listener

Te6edf3offTb4b4b4(Te6edf3eventTb4b4b4, Te6edf3handlerTb4b4b4) Tb4b4b4{

Tff7b72thisTb4b4b4.Te6edf3emitterTb4b4b4.Te6edf3offTb4b4b4(Te6edf3eventTb4b4b4, Te6edf3handlerTb4b4b4)Tb4b4b4;

Tb4b4b4}

T8b949e// emit event

Te6edf3emitTb4b4b4(Te6edf3typeTb4b4b4, Te6edf3eventTb4b4b4) Tb4b4b4{

Tff7b72thisTb4b4b4.Te6edf3emitterTb4b4b4.Te6edf3emitTb4b4b4(Te6edf3typeTb4b4b4, Te6edf3eventTb4b4b4)Tb4b4b4;

Tb4b4b4}

Te6edf3reconnectTb4b4b4(Tb4b4b4) Tb4b4b4{

Tff7b72if Tb4b4b4(Tff7b72!Tff7b72thisTb4b4b4.Te6edf3initialized Tff7b72|| Tff7b72thisTb4b4b4.Te6edf3isDemoModeTb4b4b4) Tb4b4b4{

Tff7b72returnTb4b4b4;

Tb4b4b4}

T8b949e// connect to websocket

Tff7b72const Te6edf3wsUrl Tff7b72= Te6edf3locationTb4b4b4.Te6edf3originTb4b4b4.Te6edf3replaceTb4b4b4(Ta5d6ff/^https/Tb4b4b4, Ta5d6ff"wss"Tb4b4b4)Tb4b4b4.Te6edf3replaceTb4b4b4(Ta5d6ff/^http/Tb4b4b4, Ta5d6ff"ws"Tb4b4b4) Tff7b72+ Ta5d6ff"/ws"Tb4b4b4;

Tff7b72thisTb4b4b4.Te6edf3ws Tff7b72= Tff7b72new Te6edf3WebSocketTb4b4b4(Te6edf3wsUrlTb4b4b4)Tb4b4b4;

T8b949e// auto reconnect when websocket closes

Tff7b72thisTb4b4b4.Te6edf3wsTb4b4b4.Te6edf3addEventListenerTb4b4b4(Ta5d6ff"close"Tb4b4b4, Tb4b4b4(Tb4b4b4) Tb4b4b4=> Tb4b4b4{

Tff7b72if Tb4b4b4(Tff7b72!Tff7b72thisTb4b4b4.Te6edf3isDemoModeTb4b4b4) Tb4b4b4{

Te6edf3setTimeoutTb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Tb4b4b4{

Tff7b72thisTb4b4b4.Te6edf3reconnectTb4b4b4(Tb4b4b4)Tb4b4b4;

Tb4b4b4}Tb4b4b4, T79c0ff1000Tb4b4b4)Tb4b4b4;

Tb4b4b4}

Tb4b4b4}Tb4b4b4)Tb4b4b4;

T8b949e// emit data received from websocket

Tff7b72thisTb4b4b4.Te6edf3wsTb4b4b4.Te6edf3onmessage Tff7b72= Tb4b4b4(Te6edf3messageTb4b4b4) Tb4b4b4=> Tb4b4b4{

Tff7b72thisTb4b4b4.Te6edf3emitTb4b4b4(Ta5d6ff"message"Tb4b4b4, Te6edf3messageTb4b4b4)Tb4b4b4;

Tb4b4b4}Tb4b4b4;

Tb4b4b4}

Te6edf3sendTb4b4b4(Te6edf3messageTb4b4b4) Tb4b4b4{

Tff7b72if Tb4b4b4(Tff7b72thisTb4b4b4.Te6edf3ws Tff7b72!= Tff7b72null Tff7b72&& Tff7b72thisTb4b4b4.Te6edf3wsTb4b4b4.Te6edf3readyState Tff7b72=== Te6edf3WebSocketTb4b4b4.Te6edf3OPENTb4b4b4) Tb4b4b4{

Tff7b72thisTb4b4b4.Te6edf3wsTb4b4b4.Te6edf3sendTb4b4b4(Te6edf3messageTb4b4b4)Tb4b4b4;

Tb4b4b4}

Tb4b4b4}

Te6edf3pingTb4b4b4(Tb4b4b4) Tb4b4b4{

Tff7b72if Tb4b4b4(Tff7b72thisTb4b4b4.Te6edf3isDemoModeTb4b4b4) Tb4b4b4{

Tff7b72returnTb4b4b4;

Tb4b4b4}

Tff7b72try Tb4b4b4{

Tff7b72thisTb4b4b4.Te6edf3sendTb4b4b4(

Tffa657JSONTb4b4b4.Te6edf3stringifyTb4b4b4(Tb4b4b4{

Te6edf3typeTff7b72: Ta5d6ff"ping"Tb4b4b4,

Tb4b4b4}Tb4b4b4)

Tb4b4b4)Tb4b4b4;

Tb4b4b4} Tff7b72catch Tb4b4b4{

T8b949e// ignore error

Tb4b4b4}

Tb4b4b4}

Tb4b4b4}

Tff7b72export Tff7b72default Tff7b72new Te6edf3WebSocketConnectionTb4b4b4(Tb4b4b4)Tb4b4b4;